package net.alan.etl.demo;

import java.util.Date;

import net.alan.etl.impl.AbstractFlowTaskTimer;
import net.alan.etl.kafka.FlowParams;

public class DemoTask1 extends AbstractFlowTaskTimer {

	@Override
	public String taskId() {
		return "main";
	}

	@Override
	public Date firstDate() {
		return new Date();
	}

	@Override
	public long period() {
		return 1000 * 10;
	}

	@Override
	public void executeTask() {
		System.out.println("i am main");
	}

	@Override
	public void initParam(FlowParams params) {
		super.initParam(params);
	}

	@Override
	public String monitorTaskId() {
		return null;
	}

}
